package com.jianying.test;

import org.apache.spark.sql.Dataset;
import org.apache.spark.sql.SparkSession;

public class MySparkApp {
    public static void main(String[] args) {
        SparkSession spark = SparkSession
                .builder()
                .appName("Java Spark SQL basic example")
                .master("local[*]")
                .getOrCreate();

        Dataset<String> textFile = spark.read().textFile("input/word.txt");

        textFile.show();

        spark.stop();
    }
}
